package main

func main() {
	//// 注册生产者 填入broker节点,group名称,重试次数信息
    // clicepr :=	queue.RegisterRocketProducerMust([]string{"127.0.0.1:9876"}, "test", 1)
	//// 注册消费者 填入broker节点,group名称信息
	// clicecu := queue.RegisterRocketConsumerMust([]string{"127.0.0.1:9876"},"test")
	// go func() {
	//	 for i:=0;i<10;i++  {
	//		 clicepr.SendMsg("topicTest", "Hello mq~~")
	//		 time.Sleep(10*time.Second)
	//	 }
	//
	// }()
	// //执行消费者监听，填入消息队列topic
	// clicecu.ListenReceiveMsgDo("topicTest",func(mqMsg queue.MqMsg){
	//	 // 收到一条消息
	//	 fmt.Println("receive====>",mqMsg.MsgId, mqMsg.BodyString())
	// })
	//time.Sleep(20*time.Second)
}
